cothema / reliable-socket-io-request

/**

 * Mostly for server side

 */

export class ReliableSocketRequestService {

    private emitter: ReliableSocketRequestEmitter;

    private receiver: ReliableSocketRequestReceiver;

    public constructor() {

        this.emitter = new ReliableSocketRequestEmitter();

        this.receiver = new ReliableSocketRequestReceiver();

    }

    /**

     * Returns promise with response.

     *

     * @param eventName

     * @param emitDataPack

     * @param options

     */

    public emit(

        socket: ISocketEmitter,

        eventName: string,

        body: any,

        options: Partial<IReliableSocketEmitOptions> = {},

    ): Promise<any> {

        return this.emitter.emit(socket, eventName, body, options);

    }

    public on(socket: ISocketEmitter, eventName: string, callback: () => void) {

        this.receiver.on(socket, eventName, callback);

    }

    public once(

        socket: ISocketEmitter,

        eventName: string,

        callback: () => void,

    ) {

        this.receiver.once(socket, eventName, callback);